ZeroMQ 事件驱动改造：zmq_poll 与 ZMQ_PAIR

一个常见的性能问题形态：发送队列的处理函数在 while (running) 紧凑循环中被无条件频繁调用，即使队列为空也空转，CPU 因忙等待而居高不下。本文整理一套完整的 ZeroMQ 改造方案：用 zmq_poll 把主动轮询改为事件驱动，再用 ZMQ_PAIR + inproc:// 把跨线程的发送请求也收进同一个事件循环，适合在 ZeroMQ 应用里做 CPU 优化的开发者。

zmq_poll 的工作原理

zmq_poll 是 ZeroMQ 对操作系统多路复用机制（Linux epoll、传统 poll、Windows select）的一层封装，核心行为：

1. 阻塞与等待：挂起当前线程、让出 CPU，直到任一被监视 socket 上发生感兴趣的事件（如 ZMQ_POLLIN 表示有数据可读），或指定的超时时间已到；
2. 内核监听：等待期间由内核 watch 这些文件描述符，几乎不消耗 CPU；
3. 事件返回：被唤醒后通过 zmq_pollitem_t 的 revents 字段告知是哪个 socket 上发生了什么。

与忙等待对比：主线程大部分时间休眠，只有网络消息到达、监控事件发生或内部队列有待发消息时才被唤醒并工作，从根本上消除空转。

超时时间的配置

const int rc = zmq::poll(items, 2000);  // 固定超时 2000ms

固定超时是"安全网"与响应性的权衡：

• 保证可退出：即使无任何事件，主循环也至少每 2 秒唤醒一次，能定期检查运行标志位、及时响应停止请求；
• 避免频繁唤醒：空闲时唤醒频率低，不会抵消事件驱动省下的 CPU。

超时粒度按"能容忍的停止延迟"上限设置即可，无需更小。

ZMQ_PAIR：把跨线程发送也变成事件

忙等待消除后还剩一个瓶颈：工作线程调用发送接口时，若通过互斥锁访问共享队列，主循环处理得越频繁、锁竞争越激烈。

改造方案分四步：

1. 创建一对 ZMQ_PAIR socket，用 inproc:// 协议连接——进程内通信，不经内核网络栈；
2. 发送接口不再碰共享队列和锁，直接通过 worker 侧的 PAIR socket 把消息发进管道；
3. 主循环的 zmq_poll 同时监视另一侧的 PAIR socket——有消息进管道即变为可读，立刻唤醒阻塞中的主线程；
4. 主线程从 PAIR socket 读出数据，经业务 socket 转发到网络。

zmq::pollitem_t items[] = {
    {static_cast<void*>(m_socket_main), 0, ZMQ_POLLIN, 0},  // 业务消息
    {static_cast<void*>(m_socket_mon),   0, ZMQ_POLLIN, 0}, // 连接监控事件
    {static_cast<void*>(m_pair_io),      0, ZMQ_POLLIN, 0}, // 内部待发消息
};

这个设计的好处：

• 无锁：发送线程与处理线程之间通过 ZeroMQ 内部队列通信，不再需要自定义共享数据加显式锁；
• 事件驱动：发送动作本身成为事件，立即唤醒处理线程，响应延迟极低；
• 统一事件循环：网络 I/O 与内部 I/O 都收进同一个主循环，架构更简洁易维护。

ZMQ_PAIR 的语义要点：严格的一对一连接，第一个 connect() 建立配对后，后续连接不被接受；没有其他 socket 类型的自动重连、负载均衡等高级语义。它正好适合这种"自建管道"用途，不适合做通用通信模式。inproc:// endpoint 在 context 内唯一、名字最长 256 字符，这些约束在使用时需要注意。

顺带一提：ipc:// 传输的底层原理

同一优化中，把本机的 tcp://127.0.0.1 换成 ipc:// 也能受益。ZeroMQ 的 IPC 传输在 Linux 上底层是 Unix Domain Socket（UDS），通过文件系统上的 socket 文件（如 ipc:///tmp/my_socket）标识端点：

• 不走网络协议栈：无需处理 TCP/IP 头、校验和、序列号、重传，数据可在内核中直接从一个进程缓冲区传递到另一个进程缓冲区；
• 路径短：比 TCP 本地回环（仍需遍历完整内核协议栈）更快、开销更小；
• 权限控制：可借助文件系统权限控制访问。

在 ZeroMQ 增强层之下，ipc:// 与其他传输共享同样的异步模型：应用线程调用 zmq_send() 后消息先入 ZeroMQ 内部队列，由专用 I/O 线程异步经 UDS 发出；接收端同样由 I/O 线程收下放入接收队列，应用线程从队列取——应用线程从不阻塞在底层 socket 上。

小结

这套改造的组合是：zmq_poll 负责消除主循环的空转（被动轮询 → 事件驱动），ZMQ_PAIR + inproc:// 负责消除跨线程发送的锁竞争（共享队列 → 消息管道），ipc:// 负责缩短本机传输路径（TCP 回环 → Unix Domain Socket）。三者都只改变事件的传递方式，不改变业务逻辑，可以逐项独立验证收益。